package com.grj.boot.controller;

/**
 * @author ganru
 * @date 2025/10/19 0:55
 */
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Component
public class KafkaConsumerService {

    @KafkaListener(topics = "test-topic", groupId = "demo-group")
    public void listen(String message) {
        System.out.println("📥 Received message: " + message);
    }
}
